class BackupScheduler:
    def schedule_backup(self):
        """动态调整备份策略"""
        cluster_load = self._get_cluster_load()
        if cluster_load < 30:
            self._trigger_full_backup()
        elif cluster_load < 70:
            self._trigger_incremental_backup()
        else:
            self._delay_backup()
            
    def _get_cluster_load(self):
        """获取集群负载指标"""
        cmd = "SHOW STATUS LIKE 'ob_load'"
        result = self.conn.execute(cmd)
        return int(result[0]["VALUE"])